package com.sheep.jucdemo.part11.part11_7;

import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * @Date 2022/5/31 20:58
 * @Created by sheep
 */
public class NamedThreadFactory implements ThreadFactory
{
    private static final AtomicInteger POOL_SEQ = new AtomicInteger(1);
    private final AtomicInteger mThreadNum = new AtomicInteger(1);
    private final String mPrefix;
    private final boolean mDaemon;
    private final ThreadGroup mGroup;
    public NamedThreadFactory() {
        this("pool-" + POOL_SEQ.getAndIncrement(),false);
    }
    public NamedThreadFactory(String prefix) {
        this(prefix,false);
    }
    public NamedThreadFactory(String prefix,boolean daemon) {
        mPrefix = prefix + "-thread-";
        mDaemon = daemon;
        SecurityManager s = System.getSecurityManager();
        mGroup = ( s == null ) ? Thread.currentThread().getThreadGroup() : s.getThreadGroup();
    }
    public Thread newThread(Runnable runnable) {
        String name = mPrefix + mThreadNum.getAndIncrement();
        Thread ret = new Thread(mGroup,runnable,name,0);
        ret.setDaemon(mDaemon);
        return ret;
    }
    public ThreadGroup getThreadGroup()
    {
        return mGroup;
    }
}
